package consumer

import (
	"kafkademo/pkg/kafkaex"
	"kafkademo/pkg/meta"
)

func Consume() {
	m := kafkaex.NewKafkaManager(meta.KafkaHosts...)
	err := m.Init()
	if err != nil {
		println(err.Error())
	}
	err = m.NewConsumer(meta.ConsumeGroupIdA, meta.TopicsA...)
	if err != nil {
		println(err.Error())
	}
	err = m.NewConsumer(meta.ConsumeGroupIdB, meta.TopicsB...)
	if err != nil {
		println(err.Error())
	}
	m.ConsumersGo()
}
